🌎 rns.kin.earth git 🌍

Micron Document

Node / dev / reticulum / commits / 6527423

Commit 65274235266cba54b7374eecc5ee236e3d275b15

󰉖 Browse tree at this commit

Parents : d8bc20d

Author : Mark Qvist <bc7291552be7a58f361522990465165c>

Signature : T66BB85Valid, signed by author

Date : 2026-07-20T14:55:09+02:00

Run known destinations cleaning at background priority to avoid lock contention on CPU-constrained systems

Changes

2 files changed, 11 insertions(+), 3 deletions(-)

M RNS/Identity.py +7 -2

M RNS/Transport.py +4 -1

Diff

diff --git a/RNS/Identity.py b/RNS/Identity.py

index 6cb64f97..db57218d 100644

--- a/RNS/Identity.py

+++ b/RNS/Identity.py

@@ -282,7 +282,7 @@ class Identity:

except Exception as e: RNS.log(f"Error while retaining identity {RNS.prettyhexrep(identity_hash)}: {e}", RNS.LOG_ERROR)

@staticmethod

- def clean_known_destinations():

+ def clean_known_destinations(background=False):

now = time.time()

st = now

total = len(Identity.known_destinations)

@@ -292,9 +292,13 @@ class Identity:

never_used = 0

ratchetdir = RNS.Reticulum.storagepath+"/ratchets"

+ RNS.log(f"Cleaning known destinations{' at background priority' if background else ''}...", RNS.LOG_DEBUG) if RNS.sl(RNS.LOG_DEBUG) else None

with Identity.known_destinations_lock: destination_hashes = list(Identity.known_destinations.keys())

for destination_hash in destination_hashes:

try:

+ if background: time.sleep(0.001) # Low priority, yield thread

+ RNS.Transport.destinations_last_cleaned = time.time()

if RNS.Transport.has_path(destination_hash): has_path = True

else:

has_path = False

@@ -340,7 +344,8 @@ class Identity:

if os.path.isfile(ratchet_path): os.unlink(ratchet_path)

except Exception as e: RNS.log(f"Could not clean stale ratchets for {RNS.prettyhexrep(destination_hash)}: {e}", RNS.LOG_WARNING)

- # RNS.log(f"Total destinations: {total}, stale: {len(stale)}, removed: {removed}, no path: {no_path}, never used: {never_used}, with path: {total-no_path}, used: {total-never_used}, retained: {retained}. Completed in {RNS.prettyshorttime(time.time()-st)}", RNS.LOG_WARNING) # TODO: Remove

+ RNS.log(f"Cleaned known destinations in {RNS.prettyshorttime(time.time()-st)}", RNS.LOG_DEBUG) if RNS.sl(RNS.LOG_DEBUG) else None

+ RNS.log(f"Total: {total}, stale: {len(stale)}, removed: {removed}, no path: {no_path}, never used: {never_used}, with path: {total-no_path}, used: {total-never_used}, retained: {retained}", RNS.LOG_PATHING) if RNS.sl(RNS.LOG_PATHING) else None

if not RNS.Transport.owner.is_connected_to_shared_instance: Identity.save_known_destinations(recombine=False)

@staticmethod

diff --git a/RNS/Transport.py b/RNS/Transport.py

index d893c763..c536f6b2 100755

--- a/RNS/Transport.py

+++ b/RNS/Transport.py

@@ -969,7 +969,10 @@ class Transport:

# Clean known destinations

if time.time() > Transport.destinations_last_cleaned+Transport.known_destinations_interval:

Transport.destinations_last_cleaned = time.time()

- def job(): RNS.Identity.clean_known_destinations()

+ def job():

+ try: RNS.Identity.clean_known_destinations(background=True)

+ except Exception as e: RNS.log(f"Error while running scheduled known destinations cleaning: {e}", RNS.LOG_ERROR)

+ finally: Transport.destinations_last_cleaned = time.time()

threading.Thread(target=job, daemon=True).start()

# Send announces for management destinations

Served by rngit 1.5.0 - Generated in 0.08s